package com.woniuxy.consumer.controller;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.ConcurrentHashMap;

/**
 * 手动消费获取
 */
@RestController
@RequestMapping("/consumer")
public class consumerController {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
//    @PostMapping("/simpleQueue")
//    public String simpleQueue(){
//        //手动获取
//        String msg = (String) rabbitTemplate.receiveAndConvert("simpleQueue");
//        return msg;
//    }

}
